package com.bossien.flink.interfaces;


import java.io.IOException;
import java.io.Serializable;

/***
 * @author 胡春林
 * 消息体接口
 */
public interface IMessage extends Serializable {

    <T> T JsonToMessage(String jsonBody, Class<T> beanObj) throws IOException;

    String MessageToJson(Class message);
}
